package com.ucex.common.rocketmq.consumer;

/**
 * 供第三方实现接口，会自动加载
 */
public interface MessageConsumer {

    /**
     * 接受消息
     * @param msg
     */
    public void onMessage(String msg);

    /**
     * 获取监听Topic
     * @return
     */
    public String getTopic();

    /**
     * 获取监听Topic中的TAG，如果该字段为空，默认监听该Topic下面所有消息
     * @return
     */
    public String getTag();
    
}
